/*
 *
 * Copyright (c) 2013-2021, Alibaba Group Holding Limited;
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */

// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: TxnStream.proto

package com.aliyun.polardbx.binlog.protocol;

public final class TxnStream {
    private TxnStream() {
    }

    public static void registerAllExtensions(
        com.google.protobuf.ExtensionRegistryLite registry) {
    }

    public static void registerAllExtensions(
        com.google.protobuf.ExtensionRegistry registry) {
        registerAllExtensions(
            (com.google.protobuf.ExtensionRegistryLite) registry);
    }

    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpRequest_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpRequest_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpReply_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpReply_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMessage_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMessage_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnBegin_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnBegin_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnData_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnData_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnEnd_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnEnd_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnTag_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnTag_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnToken_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnToken_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMergedToken_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMergedToken_fieldAccessorTable;
    static final com.google.protobuf.Descriptors.Descriptor
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnItem_descriptor;
    static final
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnItem_fieldAccessorTable;

    public static com.google.protobuf.Descriptors.FileDescriptor
    getDescriptor() {
        return descriptor;
    }

    private static com.google.protobuf.Descriptors.FileDescriptor
        descriptor;

    static {
        java.lang.String[] descriptorData = {
            "\n\017TxnStream.proto\022#com.aliyun.polardbx.b" +
                "inlog.protocol\"\032\n\013DumpRequest\022\013\n\003tso\030\001 \001" +
                "(\t\"P\n\tDumpReply\022C\n\ntxnMessage\030\001 \003(\0132/.co" +
                "m.aliyun.polardbx.binlog.protocol.TxnMes" +
                "sage\"\306\002\n\nTxnMessage\022>\n\004type\030\001 \001(\01620.com." +
                "aliyun.polardbx.binlog.protocol.MessageT" +
                "ype\022?\n\010txnBegin\030\002 \001(\0132-.com.aliyun.polar" +
                "dbx.binlog.protocol.TxnBegin\022=\n\007txnData\030" +
                "\003 \001(\0132,.com.aliyun.polardbx.binlog.proto" +
                "col.TxnData\022;\n\006txnEnd\030\004 \001(\0132+.com.aliyun" +
                ".polardbx.binlog.protocol.TxnEnd\022;\n\006txnT" +
                "ag\030\005 \001(\0132+.com.aliyun.polardbx.binlog.pr" +
                "otocol.TxnTag\"\253\001\n\010TxnBegin\022A\n\010txnToken\030\001" +
                " \001(\0132-.com.aliyun.polardbx.binlog.protoc" +
                "ol.TxnTokenH\000\022M\n\016txnMergedToken\030\002 \001(\01323." +
                "com.aliyun.polardbx.binlog.protocol.TxnM" +
                "ergedTokenH\000B\r\n\013token_oneof\"I\n\007TxnData\022>" +
                "\n\010txnItems\030\001 \003(\0132,.com.aliyun.polardbx.b" +
                "inlog.protocol.TxnItem\"\010\n\006TxnEnd\"\251\001\n\006Txn" +
                "Tag\022A\n\010txnToken\030\001 \001(\0132-.com.aliyun.polar" +
                "dbx.binlog.protocol.TxnTokenH\000\022M\n\016txnMer" +
                "gedToken\030\002 \001(\01323.com.aliyun.polardbx.bin" +
                "log.protocol.TxnMergedTokenH\000B\r\n\013token_o" +
                "neof\"\233\002\n\010TxnToken\022\013\n\003tso\030\001 \001(\t\022\r\n\005txnId\030" +
                "\002 \001(\t\022\023\n\013partitionId\030\003 \001(\t\022\033\n\023originMerg" +
                "eSourceId\030\004 \001(\t\022:\n\004type\030\005 \001(\0162,.com.aliy" +
                "un.polardbx.binlog.protocol.TxnType\022\r\n\005x" +
                "aTxn\030\006 \001(\010\022\026\n\016tsoTransaction\030\007 \001(\010\022\017\n\007tx" +
                "nSize\030\010 \001(\005\022\023\n\013beginSchema\030\t \001(\t\022\022\n\nallP" +
                "arties\030\n \003(\t\022\017\n\007payload\030\013 \001(\014\022\023\n\013snapsho" +
                "tSeq\030\014 \001(\003\"\177\n\016TxnMergedToken\022\013\n\003tso\030\001 \001(" +
                "\t\022:\n\004type\030\002 \001(\0162,.com.aliyun.polardbx.bi" +
                "nlog.protocol.TxnType\022\023\n\013beginSchema\030\003 \001" +
                "(\t\022\017\n\007payload\030\004 \001(\014\"Q\n\007TxnItem\022\017\n\007traceI" +
                "d\030\001 \001(\t\022\021\n\trowsQuery\030\002 \001(\t\022\021\n\teventType\030" +
                "\003 \001(\005\022\017\n\007payload\030\004 \001(\014*?\n\013MessageType\022\t\n" +
                "\005WHOLE\020\000\022\t\n\005BEGIN\020\001\022\010\n\004DATA\020\002\022\007\n\003END\020\003\022\007"
                +
                "\n\003TAG\020\004*k\n\007TxnType\022\007\n\003DML\020\000\022\017\n\013FORMAT_DE" +
                "SC\020\001\022\014\n\010META_DDL\020\002\022\016\n\nMETA_SCALE\020\003\022\024\n\020ME" +
                "TA_DDL_PRIVATE\020\004\022\022\n\016META_HEARTBEAT\020\0052z\n\n" +
                "TxnService\022l\n\004dump\0220.com.aliyun.polardbx" +
                ".binlog.protocol.DumpRequest\032..com.aliyu" +
                "n.polardbx.binlog.protocol.DumpReply\"\0000\001" +
                "B)\n#com.aliyun.polardbx.binlog.protocolH" +
                "\001P\001b\006proto3"
        };
        descriptor = com.google.protobuf.Descriptors.FileDescriptor
            .internalBuildGeneratedFileFrom(descriptorData,
                new com.google.protobuf.Descriptors.FileDescriptor[] {
                });
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpRequest_descriptor =
            getDescriptor().getMessageTypes().get(0);
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpRequest_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_DumpRequest_descriptor,
            new java.lang.String[] {"Tso",});
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpReply_descriptor =
            getDescriptor().getMessageTypes().get(1);
        internal_static_com_aliyun_polardbx_binlog_protocol_DumpReply_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_DumpReply_descriptor,
            new java.lang.String[] {"TxnMessage",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMessage_descriptor =
            getDescriptor().getMessageTypes().get(2);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMessage_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnMessage_descriptor,
            new java.lang.String[] {"Type", "TxnBegin", "TxnData", "TxnEnd", "TxnTag",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnBegin_descriptor =
            getDescriptor().getMessageTypes().get(3);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnBegin_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnBegin_descriptor,
            new java.lang.String[] {"TxnToken", "TxnMergedToken", "TokenOneof",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnData_descriptor =
            getDescriptor().getMessageTypes().get(4);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnData_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnData_descriptor,
            new java.lang.String[] {"TxnItems",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnEnd_descriptor =
            getDescriptor().getMessageTypes().get(5);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnEnd_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnEnd_descriptor,
            new java.lang.String[] {});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnTag_descriptor =
            getDescriptor().getMessageTypes().get(6);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnTag_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnTag_descriptor,
            new java.lang.String[] {"TxnToken", "TxnMergedToken", "TokenOneof",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnToken_descriptor =
            getDescriptor().getMessageTypes().get(7);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnToken_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnToken_descriptor,
            new java.lang.String[] {
                "Tso", "TxnId", "PartitionId", "OriginMergeSourceId", "Type", "XaTxn", "TsoTransaction", "TxnSize",
                "BeginSchema", "AllParties", "Payload", "SnapshotSeq",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMergedToken_descriptor =
            getDescriptor().getMessageTypes().get(8);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnMergedToken_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnMergedToken_descriptor,
            new java.lang.String[] {"Tso", "Type", "BeginSchema", "Payload",});
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnItem_descriptor =
            getDescriptor().getMessageTypes().get(9);
        internal_static_com_aliyun_polardbx_binlog_protocol_TxnItem_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_com_aliyun_polardbx_binlog_protocol_TxnItem_descriptor,
            new java.lang.String[] {"TraceId", "RowsQuery", "EventType", "Payload",});
    }

    // @@protoc_insertion_point(outer_class_scope)
}
